package com.tencent.cloud.iov.util.rx.proxy;

import io.reactivex.Observer;
import io.reactivex.functions.Action;

/**
 * {@link Observer#onComplete()} 代理类
 *
 * @author showxiao
 * @date 2018/3/30
 */

public class CompleteActionProxy<T> implements Action {

    private final Observer<T> mObserver;

    public CompleteActionProxy(Observer<T> observer) {
        mObserver = observer;
    }

    @Override
    public void run() throws Exception {
        mObserver.onComplete();
    }
}
